//package com.lgc.provider01.controller;
//
//import org.apache.rocketmq.client.producer.DefaultMQProducer;
//import org.apache.rocketmq.common.message.Message;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RestController;
//
///**
// * @param
// * @author lvguangchun
// * @create 2022-08-25 13:45
// */
//@RestController
//public class ProducerController {
//    /**
//     * 不能发一次消息，换一次 group ,因此 DefaultMQProducer 需要注入 ，主要作用是说明 procuder 的身份
//     */
//    @Autowired
//    private DefaultMQProducer defaultMQProducer;
//
//    @Value("${rocketmq.topic}")
//    private String topic;
//
//    @GetMapping("/send-message")
//    public String sendMessage() {
//
//        for (int i = 0; i < 1; i++) {
//            Message message = new Message(this.topic, "springboot 整合 rocketmq 发送的消息".getBytes());
//            try {
//                defaultMQProducer.send(message);
//            } catch (Exception e) {
//                e.printStackTrace();
//                System.out.println(String.format("producer is error {}", e.getMessage(), e.getStackTrace()));
//            }
//        }
//        return "OK,success";
//    }
//
//}
